//package com.jacky.rxjava.v120;
//
//import rx.Observable;
//import rx.Observer;
//import rx.subjects.BehaviorSubject;
//
//import java.util.concurrent.TimeUnit;
//
///**
// * @program: 智灵时代广州研发中心
// * @description:
// * @author: 吞星(yangguojun)
// * @create: 2021-12-28 10:23
// **/
//public class RXJaveDemo2 {
//
//
//    public static void testWindows() {
//        BehaviorSubject<String> observable = BehaviorSubject.create();
//        Observable<Observable<String>> windowObservable = observable.window(2);
//        windowObservable.subscribe(new Observer<Observable<String>>() {
//            private int i = 0;
//            @Override
//            public void onCompleted() {
//                System.out.println("===========onCompleted============");
//            }
//
//            @Override
//            public void onError(Throwable e) {
//
//            }
//
//            @Override
//            public void onNext(Observable<String> stringObservable) {
//                System.out.println("第" + (i++)+"聚合请求");
//                stringObservable.subscribe(new Observer<String>() {
//                    @Override
//                    public void onCompleted() {
//                        System.out.println("--------------onCompleted12312-----------");
//                    }
//
//                    @Override
//                    public void onError(Throwable e) {
//                        System.out.println("--------------onError-----------");
//
//                    }
//
//                    @Override
//                    public void onNext(String s) {
//                        System.out.println("接收到事件=" + s);
//                    }
//                });
//            }
//        });
///*        for (int i = 0; i < 10; i++) {
//            //200ms生产一个数据，
//            observable.onNext("songyao");
//            try {
//                Thread.sleep(1000);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//        }*/
//        observable.onNext("songyao1");
//        observable.onNext("songyao2");
//        observable.onNext("songyao3");
//    }
//
//
//    public static void main(String[] args) {
//        testWindows();
//    }
//
//}
